#!/usr/bin/env python
# -*- coding: UTF-8 -*-
'''
@Project ：图灵学习 
@File    ：7.aiomysql的简单使用.py
@IDE     ：PyCharm 
@Author  ：ChenLiGao
@Date    ：2024-12-17 14:37
'''
import asyncio

import aiomysql

async def main():
    aiomysql_db = await aiomysql.connect(host='localhost', port=3306, user='root', password='123456', db='py_spider')
    cursor = await aiomysql_db.cursor()

    await cursor.execute('select * from tx_work;')
    results = await cursor.fetchall()
    print(results)

    print("-----" * 20)

    print(cursor.description) # 可以使用当前方法查询表中的字段信息

    # 关闭游标必须使用await关闭
    await cursor.close()
    aiomysql_db.close()

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())